package com.deep.flink.rocketmq;

public class Test {
    public static void main(String[] args) {
//        CREATE TABLE rocketmq_source (
//                `user_action_string` STRING
//        ) WITH (
//                'connector' = 'rocketmq',
//                'topic' = 'USER_ACTION_LOG_TOPIC',
//                'consumerGroup' = 'new_cdc_user-action-group',
//                'nameServerAddress' = '192.168.12.198:9876'
//        );
//
//        select * from rocketmq_source;



    }
}
